package com.health.listener;


import com.health.pojo.Product;
import org.springframework.amqp.rabbit.annotation.Queue;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/**
 * 消息消费者-接受消息队列的消息
 * 实质为一个监听器,在消息队列门口等待接收消息
 * 放入spring容器
 * 一个方法对应一个消费者
 * 简单模式-一个生产者发送消息到消息队列,被一个消费者接收到
 */
@Component
public class Listener1 {

    /**
     * 简单消息队列-接收字符串
     */
    @RabbitListener(queuesToDeclare = @Queue("message.queue1"))
    public void listener1(String message){
        System.out.println("接收到的消息为:"+message);
    }

    /**
     * 简单消息队列-接收对象
     */
    @RabbitListener(queuesToDeclare = @Queue("message.queue2"))
    public void listener2(Product product){
        System.out.println("接收到的消息为:"+product);
    }
}
